package cn.felord.debezium.handle.columnHandle;

import cn.felord.debezium.annotation.Executor;
import org.apache.kafka.connect.data.Struct;

import java.util.Map;

public interface ColumnHandleExecutor {
    public void handleInsert(Map<String, Object> payload);
    public void handleUpdate(Struct before,Struct after);
    public void handleDelete(Map<String, Object> payload);
}
